package com.shanks.framework.mq.common.constant;

public interface MQConstant {
    /**
     * 消息主题
     */
    interface TOPIC {
        /**
         * 消息ack topic
         */
        String ACK_MSG_TOPIC = "common_ack";
    }

    /**
     * 消息属性
     */
    interface MSG {
        /**
         * 消息来源
         */
        String MSG_SOURCE = "MSG_SOURCE";
        /**
         * 消息TOPIC
         */
        String MSG_TOPIC = "MSG_TOPIC";
        /**
         * 消息KEY
         */
        String MSG_KEY = "MSG_KEY";
        /**
         * 消息TAG
         */
        String MSG_TAG = "MSG_TAG";
        /**
         * 消息主体
         */
        String MSG_BODY = "MSG_BODY";

        String PROPERTY_SIGNATURE = "signature";
    }

    interface CONSUMER {
        /**
         * 消费模式
         */
        interface MESSAGE_MODEL {
            /**
             * 集群
             */
            String CLUSTER = "CLUSTERING";

            /**
             * 广播
             */
            String BROADCASTING = "BROADCASTING";

        }

    }


    /**
     * 消息附加属性
     */
    interface PROPERTY {
        /**
         * 原始topic
         */
        String ORIGIN_TOPIC = "originTopic";
        /**
         * 原始key
         */
        String ORIGIN_KEY = "originKey";
        /**
         * 原始tag
         */
        String ORIGIN_TAG = "originTag";
        /**
         * 结果
         */
        String RESULT = "result";
        /**
         * 来源
         */
        String SOURCE = "source";
    }

}
